//package com.bins.reactor.demo1;
//
//public interface Subscriber<T> {
//
//    // 订阅时 出版商调用此方法，将订阅管理发送给订阅者
//    void onSubscribe(Subscription var1);
//
//    // 出版商调用此方法向订阅者发送数据
//    void onNext(T var1);
//
//    // 数据传输的
//    void onError(Throwable var1);
//
//    // 完成时触发
//    void onComplete();
//}
